package com.edgardeng.hello;

import com.edgardeng.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

/**
 * RabbitMQ 测试 Hello World - 发布者发送消息
 *
 */
public class Sender {
    public static void main(String[] args) throws Exception{
        String queueName = ConnectionUtil.QUEUE_NAME_HELLO_WORLD;

        // 获取连接
        Connection connection = ConnectionUtil.getConnection();
        // 创建通道
        Channel channel = connection.createChannel();

        // 声明队列，如果不存在创建，否则不作为
        // arg1: 队列的名字
        // arg2: 是否持久化
        // arg3: 是否排外
        // arg4: 是否自动删除
        // arg5: 其他参数
        channel.queueDeclare(queueName, false,false,false,null);
        String message = "I'm sending Hello World";
        // 发送内容
        channel.basicPublish("", queueName,null, message.getBytes());
        System.out.println(" [x] Sent '" + message + "'");
        // 关闭连接
        channel.close();
        connection.close();
    }


}
